package cn.tk.service.log.queue;

import cn.tk.model.entity.mr.OutcallCollect;

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;

/**
 * Created by denglw on 2019/8/1.<br/>
 * Desc: 外呼信息采集 入库队列
 */
public class OutcallCollectQueue extends BaseQueue<OutcallCollect> {

    private static final OutcallCollectQueue INSTANCE = new OutcallCollectQueue(new LinkedBlockingQueue<>(5000));

    private OutcallCollectQueue(BlockingQueue<OutcallCollect> queue) {
        super(queue);
    }

    public static OutcallCollectQueue getInstance() {
        return INSTANCE;
    }

}
